package com.song.study.springcloudconsumer.stream;

import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

@Component
public class TestConsumer {

    @StreamListener("testTopic")
    public void process(Object message){
        System.out.println("received message ... " + message);
    }
}
